package com.sh.data.engine.domain.datadev.flink.model.domain;

import lombok.Data;

import java.util.List;

/**
 * @author: zigui.zdf
 * @description:
 * @date: 2021/6/4 10:34
 */
@Data
//@ApiModel
public class FlinkSinkDomain {

    /**
     * 数据源类型
     */
    private String dsType;

    /**
     * 数据源id
     */
    private Long dsId;

    /**
     * 映射表
     */
    private String mappingTableName;

    /**
     * 映射字段
     */
    private List<FlinkFieldDomain> fieldList;

    /**
     * 并行度
     */
    private Integer parallel;

    //    @ApiModelProperty(value = "kafka类型的sink")
    private KafkaSinkDomain kafkaSink;

    //    @ApiModelProperty(value = "jdbc类型的sink")
    private JDBCSinkDomain jdbcSink;

    private HbaseSinkDomain hbaseSinkDomain;
    private String rowKeyName;
    private String rowKeyType;

    private HiveSinkDomain hiveSinkDomain;
}
